local redisClass = require("luaScript.redis.RedisOperator");
local redisObj = redisClass:new();


local ok = redisObj:open();
if not ok then
    ngx.say("redis打开失败");
    return;
end
-- 获取连接
-- local redis = redisObj:getConnection();
local res = redisObj:setValue("bigdata", "flink");
if not res then
    ngx.say("redis设置值失败");
    return;
end
redisObj:hsetValue("hadoop","stream", "flink");
ngx.say("bigdata = ", redisObj:getValue("bigdata"), "<br/>");
ngx.say("关闭redis连接","<br/>");
local res, err = redisObj:close();
ngx.say("redis连接关闭：",res, "&nbsp;&nbsp;", err);
